package com.sl.cdc.modular.debezium;

import io.debezium.engine.DebeziumEngine;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class CdcDebeziumConnectorCallback implements DebeziumEngine.ConnectorCallback {

    @Override
    public void connectorStarted() {
        // nothing by default
        log.info("connectorStarted....");
    }

    @Override
    public void connectorStopped() {
        // nothing by default
        log.info("connectorStopped....");
    }

    @Override
    public void taskStarted() {
        // nothing by default
        log.info("taskStarted....");
    }

    @Override
    public void taskStopped() {
        // nothing by default
        log.info("taskStopped....");
    }
}
